package requestCase01

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}

object HotItemAnalyse {
  def main(args: Array[String]): Unit = {

    val context = new SparkContext(new SparkConf().setAppName("HotItemAnalyse").setMaster("local[*]"))

    val textRDD: RDD[String] = context.textFile("data/user_visit_action.txt")
    //    textRDD.map(
    //      _.split("_")
    //    )
    val l: Long = textRDD.count()
    println(l+"================================")

    context.stop()
  }

}
